package com.源码分析.合并;

import reactor.core.publisher.Flux;

public class ConcatDemo {

	public static void main(String[] args) {
		// 通过向下游转发接收的元素来连接所有数据源，当操作符连接两个流时，他首先消费并重新发送第一个流的所有元素，然后对第二个流执行相同的操作
		Flux.concat(
			Flux.range(1, 3),
			Flux.range(4, 2),
			Flux.range(6, 5)
		).subscribe(System.out::println);
	}

}
